org.springframework.web.servlet.mvc.method.annotation

Class ReactiveTypeHandler.TextEmitterSubscriber

java.lang.Object

org.springframework.web.servlet.mvc.method.annotation.ReactiveTypeHandler.AbstractEmitterSubscriber

org.springframework.web.servlet.mvc.method.annotation.ReactiveTypeHandler.TextEmitterSubscriber

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

ReactiveTypeHandler

private static class ReactiveTypeHandler.TextEmitterSubscriber
extends ReactiveTypeHandler.AbstractEmitterSubscriber

Constructor Summary

Constructors

Constructor and Description
TextEmitterSubscriber(ResponseBodyEmitter emitter, TaskExecutor executor)

Method Summary

Modifier and Type	Method and Description
protected void	send(java.lang.Object element)

Methods inherited from class org.springframework.web.servlet.mvc.method.annotation.ReactiveTypeHandler.AbstractEmitterSubscriber

connect, getEmitter, onComplete, onError, onNext, onSubscribe, run

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TextEmitterSubscriber

TextEmitterSubscriber(ResponseBodyEmitter emitter,
                      TaskExecutor executor)

Method Detail

send

protected void send(java.lang.Object element)
             throws java.io.IOException

Specified by:

send in class ReactiveTypeHandler.AbstractEmitterSubscriber

Throws:

java.io.IOException